package com.movitech.mobile.mq;

/**
 * RabbitMq消息消费
 * @author luodengzhong
 * @version 1.0.0
 * @createTime 2021/8/17
 * @copyright Copyright ©️ 2021 北京魔马科技
 */
public interface RabbitmqConsumer {

    void init();

    /**
     * 流程事件消息处理
     *
     * @param data
     * @return
     * @author luodengzhong
     * @version 1.0.0
     * @createTime 2021/8/17
     * @copyright Copyright ©️ 2021 北京魔马科技
     */
    boolean consume(String queueName,String data);

    /**
     * 流程事件消息处理失败回调方法
     *
     * @param message
     * @param throwable
     * @return
     * @author luodengzhong
     * @version 1.0.0
     * @createTime 2021/8/17
     * @copyright Copyright ©️ 2021 北京魔马科技
     */
    void error(String queueName,String message, Throwable throwable);

}
